package cn.zy._01sync;

import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.remoting.common.RemotingHelper;

public class Producer {
	public static void main(String[] args) throws Exception {
    	// 创建生产者，指定组名
        DefaultMQProducer producer = new DefaultMQProducer("hello-consumer-group");
    	// 连接MQ，设置NameServer的地址
    	producer.setNamesrvAddr("localhost:9876");
    	// 启动生产者Producer实例
        producer.start();
    	    // 创建消息，并指定Topic，Tag和消息体
    	    Message msg1 = new Message("hello-topic1" /* Topic */,
        	"hello-topic1" /* Tag */,
        	("阿尔托莉雅潘德拉贡").getBytes(RemotingHelper.DEFAULT_CHARSET) /* Message body */
        	);
        	// 发送消息到一个Broker
            SendResult res1 = producer.send(msg1);
            // 通过sendResult返回消息是否成功送达
            System.out.println(res1);
		// 如果不再发送消息，关闭Producer实例
		producer.shutdown();
    	}


    }
